package com.runjian.rundo.iot.agent.business.publisher;

import com.runjian.rundo.iot.agent.common.message.DecodedMessage;

/**
 * mq消息发布器
 *
 * @author LiGang
 */
public interface MessagePublisher {

    /**
     * 发送设备属性消息
     *
     * @param decodedMessage 消息内容
     */
    void sendDeviceMessage(DecodedMessage decodedMessage);

    /**
     * 发送虚拟电厂总指令属性消息
     *
     * @param vppMessage 消息内容
     */
    void sendVppMessage(DecodedMessage vppMessage);
    /**
     * 发送内容
     * 
     * @param topic topic
     * @param obj 内容
     */
    void send(String topic, Object obj);

}
